package com.iiixxxiii.pf.api.kafka;

import java.util.concurrent.ExecutionException;
/**
 * kafka测试类 消费者
 *
 */
public class TestKafkaConsumer {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        //添加消费者
        KafkaConsumerTemplate consumer = new KafkaConsumerTemplate("127.0.0.1:9092", "org.apache.kafka.common.serialization.StringDeserializer", "org.apache.kafka.common.serialization.StringDeserializer", "test.group", "test.topic");
        KafkaTools.addConsumer(KafkaTools.defaultName, consumer);
    }
}
